package pers.cz.logtail.queue;

import pers.cz.logtail.queue.kafka.KafkaFactory;

/**
 * @program: JefLogTail
 * @description: 抽象工厂
 * @author: Cheng Zhi
 * @create: 2023-03-15 17:41
 **/
public abstract class AbstractQueueFactory implements QueueFactory{

    public static QueueFactory getInstance(QueueConf conf) {

        if (QueueEnum.KAFKA == conf.getQueueType()) {
            return new KafkaFactory(conf);
        }

        return null;
    }


}
